class KafkaExtension extends CompilerExtension
{
    public function __construct()
    {
        $this->kafkaConfig = new KafkaConfig();
    }

    protected function loadConfiguration(): void
    {
        // ...
        foreach ($clusters as $clusterName => $clusterConf) {
            // ...
            $clusterTemplate = new ClusterTemplate($clusterName, [], $options, $callbacks);
            $this->kafkaConfig->addClusterTemplate($clusterTemplate);
            // ...
     }

     public function setupDefinitions(): void
     {
        $builder = $this->getContainerBuilder();
        $builder->addDefinition($this->prefix('producerFactory'))
            ->setFactory(ProducerFactory::class)
            ->setAutowired($this->config[self::AUTOWIRED] ?? true)
            ->setArguments([$this->kafkaConfig, $this->configurationHelper]);
         // ...
     }
}

final readonly class ConsumerFactory
{
    public function __construct(
        private KafkaConfig $kafkaConfig, 
        private ConfigurationHelper $configurationHelper
    ) {
    }

    public function createConsumer(string $consumerName, ?Callbacks $callbacks = null, array $customConf = []): KafkaConsumer
    {
        $consumerTemplate = $this->kafkaConfig->getConsumerTemplate($consumerName);
        // ...
        return new KafkaConsumer($conf, $consumerTemplate);
    }
}